package faas

import (
	"context"
	"flow-calc/core"
	"flow-calc/core/log"
)

func FuncDemo3(ctx context.Context, flow core.Flow) error {
	log.Logger().InfoCtx(ctx, "---------------> %s <----------------", "第三个业务函数: FuncDemo3")

	for _, row := range flow.Input() {
		// 输出接收的参数数据
		log.Logger().Info("入参: funcName = %s, funcID=%s, 数据: %+v", flow.GetExecFuncConf().FName, flow.GetExecFunction().GetId(), row)
	}
	return nil
}
